package cn.tedu.csmall.stock.webapi.quartz;


import cn.tedu.csmall.commons.pojo.stock.model.StockTb;
import cn.tedu.csmall.stock.webapi.quartz.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

// 当前类也要实例化对象保存到Spring容器才能实现监听效果
@Component
// 和Kafka不同,RabbitMQ的监听器注解编写在类上
@RabbitListener(queues = {RabbitMQConfig.STOCK_QUEUE})
public class RabbitMQConsumer {

    // 在类上编写监听,但是运行的也一定是个方法
    // 所以我们需要使用下面注解标记这个方法,让队列有消息时运行这个方法
    // 一个类只能有一个方法标记这个注解
    // 这个方法直接声明参数,就是消息的值,支持Object类型
    @RabbitHandler
    public void process(String str){
        System.out.println("消息的接收者看到消息:"+str);
    }


}
